package com.fadadianqi.logistics.customer.dao;

import com.fadadianqi.commons.BaseDAO;
import com.fadadianqi.logistics.customer.model.MsgQueue;
import com.yeqiangwei.commons.util.Pagination;

import java.util.List;

public interface MsgQueueDAO extends BaseDAO<MsgQueue> {

    List<MsgQueue> findByJobIdAndStatus(String jobId, int status,
                                        Pagination pagination);

    List<MsgQueue> findByJobId(String jobId, Pagination pagination);

    int countByJobId(String id);

    int countQueueByJobIdAndStatus(String jobId, int status);

    void cancelQueueByJobId(String jobId);

    void removeByJobId(String jobId);

}
